// dao/userDao.js
// 实现与MySQL交互
var mysql = require('mysql');
var $conf = require('../conf/db');
var $sql = require('./welcomeDao');

// 使用连接池，提升性能
var pool  = mysql.createPool($conf.mysql);

// 向前台返回JSON方法的简单封装
var jsonWrite = function (res, ret) {
    if(typeof ret === 'undefined') {
        res.json({
            code:'1',
            msg: '操作失败'
        });
    } else if(ret[0]!=null){
        res.json({code:'200',result:{states:'success',json:ret}});
    }

};

module.exports = {
    queryAll:function(req,res){
        pool.getConnection(function(err, connection) {
            connection.query($sql.queryAll,function(err, result) {
                jsonWrite(res,result);
                connection.release();
                return result;
            });
        });
    }
};